package cn.lgwen.candy.runtime.driver;

/**
 * 2019/12/24
 * aven.wu
 * danxieai258@163.com
 */
public interface Driver {

    default void cancel() {}
    /**
     * get data from upstream and forward to next process
     */
    void run();

    void parallel(int parallel);

    int parallel();

    void checkpoint(boolean checkpoint);

    default boolean checkpoint() {
        return false;
    }
}
